package com.xtck.ha.common.consumer;

import org.springframework.kafka.annotation.KafkaListener;
import org.springframework.stereotype.Service;

/**
 * Kafaka消费端
 */
@Service
public class KafkaConsumer {

    @KafkaListener(topics = "characterHandle", groupId = "zq-group")
    public void saveLog(String msg) throws Exception {
       System.out.println("收到消息："+msg);
    }

}
